package com.reason.canal.listener;

//import com.alibaba.otter.canal.protocol.CanalEntry;
import com.reason.canal.feign.EsManagerFeign;
//import com.wwjd.starter.canal.annotation.CanalEventListener;
//import com.wwjd.starter.canal.annotation.ListenPoint;
import org.springframework.beans.factory.annotation.Autowired;
//
//*监听类
// * @author zhangHeng
// * @date 2020/7/2 16:56
//
//@CanalEventListener
public class CustomerListener {
//
//    @Autowired
//    private EsManagerFeign esManagerFeign;
//
//    @ListenPoint(schema = "hw", table = {"reason_customer","reason_condition","reason_marriage","reason_job","reason_economics","reason_lifestyle"})
//    public void adUpdate(CanalEntry.EntryType entryType, CanalEntry.RowData rowData){
//        System.out.println("数据发生改变");
//        //当数据发生改变更新索引库
//        esManagerFeign.importAll();
//
//    }
}
